@pytest.mark.xfail_safari
 @pytest.mark.xfail_firefox
 @pytest.mark.xfail_opera
-async def test_add_request_handler(driver):
-
+@pytest.mark.parametrize("original_url,redirected_url", [
+    ("https://www.example.com/", "https://www.selenium.dev/about/"),
+    ("https://www.example.org/", "https://www.selenium.dev/documentation/"),
+    ("https://www.example.net/", "https://www.selenium.dev/downloads/"),
+])
+async def test_add_request_handler(driver, original_url, redirected_url):
     def request_filter(params: BeforeRequestSentParameters):
-        return params.request["url"] == "https://www.example.com/"
+        return params.request["url"].startswith("https://www.example.")
 
     def request_handler(params: BeforeRequestSentParameters):
         request = params.request["request"]
         json = {
             "request": request,
-            "url" : "https://www.selenium.dev/about/"
+            "url": redirected_url
         }
         return ContinueRequestParameters(**json)
 
     await driver.network.add_request_handler(request_filter, request_handler)
-    driver.get("https://www.example.com/")
-    assert driver.current_url == "https://www.selenium.dev/about/"
+    driver.get(original_url)
+    assert driver.current_url == redirected_url

+import logging
+
 def _callback(self, request_filter, handler):
     async def callback(request):
-        if request_filter(request):
-            request = handler(request)
-        else:
-            request = default_request_handler(request)
-        await self.network.continue_request(request)
+        try:
+            if request_filter(request):
+                request = handler(request)
+            else:
+                request = default_request_handler(request)
+            await self.network.continue_request(request)
+        except Exception as e:
+            logging.error(f"Error handling request: {e}")
+            # Consider implementing a fallback behavior here
 
     return callback

 @property
 def network(self):
     if not self._network:
-        self._network = Network(self.caps.get("webSocketUrl"))
-
+        if "webSocketUrl" not in self.caps:
+            raise ValueError("WebSocket URL not found in capabilities")
+        self._network = Network(self.caps["webSocketUrl"])
     return self._network

 async def add_request_handler(self, request_filter=lambda _: True, handler=default_request_handler):
     async with open_cdp(self.ws_url) as conn:
         if not self.network:
             self.network = network.Network(conn)
         params = AddInterceptParameters(["beforeRequestSent"])
         result = await self.network.add_intercept(event=BeforeRequestSent, params=params)
         intercept = result["intercept"]
         callback = self._callback(request_filter, handler)
         await self.network.add_listener(BeforeRequestSent, callback)
-        return intercept
+        return intercept, lambda: self.network.remove_listener(BeforeRequestSent, callback)